package com.cm.log_process.log_common.encoder;



import com.alibaba.fastjson.JSON;
import com.cm.log_process.log_common.entity.Log;

import javax.websocket.EncodeException;
import javax.websocket.Encoder;
import javax.websocket.EndpointConfig;

/**
*@Date 2019/12/10
*@Author 郭兆鹏
*作用：日志解码器，用于WebSocket的发送object请求，统一规范解码格式
*
*/
public class LogEncoder implements Encoder.Text<Log> {
    @Override
    public String encode(Log log) throws EncodeException {
        //暂时使用fastJson
        return JSON.toJSONString(log);
    }

    @Override
    public void init(EndpointConfig endpointConfig) {
        System.out.println("初始化encoder");
    }

    @Override
    public void destroy() {
       System.out.println("销毁encoder");
    }
}
